#!/usr/bin/env python3
"""
测试Qwen服务的日志输出
"""
import asyncio
from app.services.qwen_service import QwenVLService
from app.utils.logger import logger

async def test_qwen_logging():
    """测试Qwen服务的日志输出"""
    try:
        print("🧪 测试Qwen服务日志输出...")
        
        qwen_service = QwenVLService()
        
        # 1. 测试连接（会有日志输出）
        print("\n1️⃣ 测试连接...")
        try:
            connection_ok = await qwen_service.test_connection()
            print(f"连接结果: {connection_ok}")
        except Exception as e:
            print(f"连接测试异常: {e}")
        
        # 2. 测试文本分析（如果连接成功）
        print("\n2️⃣ 测试文本分析...")
        try:
            result = await qwen_service.analyze_text("请简单回答：1+1等于多少？")
            print(f"文本分析结果: {result}")
        except Exception as e:
            print(f"文本分析异常: {e}")
        
        # 3. 测试视频分析（使用一个测试URL）
        print("\n3️⃣ 测试视频分析...")
        try:
            test_url = "http://192.168.210.72:8000/videos/24772cca-7b78-4d7f-a836-7302659ea177.mp4"
            result = await qwen_service.analyze_video_by_url(test_url, "请简单描述这个视频")
            print(f"视频分析结果: {result[:100]}...")
        except Exception as e:
            print(f"视频分析异常: {e}")
        
        print("\n✅ 测试完成！请查看上面的日志输出。")
        
    except Exception as e:
        print(f"❌ 测试失败: {e}")
        import traceback
        traceback.print_exc()

if __name__ == "__main__":
    asyncio.run(test_qwen_logging())